# 测试例程
import os,sys,time

# 定义管道名称
fifo_r = "/tmp/gdl703t_R_data"

pcm_f = open("001.pcm","wb+")

# 打开管道
if not os.path.exists(fifo_r):
    os.mkfifo(fifo_r)
fd = os.open(fifo_r, os.O_RDONLY)



# 读取管道中的数据
while True:
    data = os.read(fd, 1280)
    pcm_f.write(data)
    # print("Data received from Pipe: ", data)

# 关闭管道
os.close(fd) 
os.unlink(fifo_r)